package org.shj.hadoop.customer;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Partitioner;

public class CustomerPartition extends Partitioner<KeyPair, Text>{

	public int getPartition(KeyPair key, Text value, int numPartitions) {
		return (key.getYear() * 127) % numPartitions;
	}

}
